import Sensors.Alarm;
import Sensors.Smoke;


public class FromMorse implements Runnable {
	
	SpecificCollector speColl;
	
	public FromMorse () {
		// Création du collecteur de Frameself
		speColl = new SpecificCollector();
	}

	@Override
	public void run() {
		collectData ();
	}

	private void collectData() {
		int i = 0;
		Smoke smoke;
		Alarm alarm;
		
		//Boucle de test
		while(true){
			//Création de la donnée récupérée
			if (i < 10)
				smoke = new Smoke(200, "home");
			else
				smoke = new Smoke(500, "home");
			//Envoi de la donnée au collecteur de Frameself
			speColl.sendData(smoke);
			
			//Création de la donnée récupérée
			if ((i>=2) && (i<=11))
				alarm = new Alarm(false, "home");
			else
				alarm = new Alarm(true, "home");
			//Envoi de la donnée au collecteur de Frameself
			speColl.sendData(alarm);
			
			try {
				// waiting for 1 second
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			i = (i+1)%20;
		}
	}

}
